//package _rxjava2;
//
///**
// * @author huangya
// * @date 2022/7/8
// */
//public class FlowableDemo {
//
//    public static void main(String[] args) {
//        package com.crazymaker.demo.rxJava.basic;
//        //省略
//         import
//        @Slf4j
//        public class BackpressureDemo {
//        // /** *演示不使用背压 */
//        @Test public void testNoBackpressure () throws InterruptedException {
//            //被观察者（主题）
//            Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
//                @Override
//                public void call(Subscriber<? super String> subscriber) {
//                    //循环10次
//                     for (int i = 0;i<10 ; i++) { log.info("produce ->" + i); subscriber.onNext(String.valueOf(i)); } } });
//            //观察者
//         Action1<String> subscriber = new Action1<String>() {
//             public void call(String s){ try {
//                 //每消费一次间隔50毫秒
//                  Thread.sleep(50); } catch (InterruptedException e) { e.printStackTrace(); } log.info("consumer ->" + s); } };
//         //订阅:observable与subscriber之间依然通过subscribe()进行关联
//         observable .subscribeOn(Schedulers.io()) .observeOn(Schedulers.newThread()) .subscribe(subscriber);
//                     Thread.sleep(Integer.MAX_VALUE); }}
//                }
//            }
